package cn.enjoyedu.service;

import org.apache.kafka.clients.producer.RecordMetadata;
import org.springframework.kafka.support.ProducerListener;

/**
 * 类说明：发送者确认
 */
public class SendListener implements ProducerListener<String, Object> {
    @Override
    public void onSuccess(String topic, Integer partition, String key, Object value, RecordMetadata recordMetadata) {
        System.out.println("topic = " + topic + " partition = " + partition + " key = " + key + " value = " + value);
    }
}
